package cn.dmp.util

import org.apache.spark.rdd.RDD
import scalikejdbc._
import scalikejdbc.config._

/**
  * 需要导入Scalike依赖   以及  对应的配置文件
  */
object ScalikeSqlManger {

  // 加载配置信息
  DBs.setup()

  /**
    * 统计各省市数据量分布情况
    *
    * @param jsonInfo
    */
  def saveProvenceInfojsonInfo(jsonInfo: RDD[String]): Unit = {

    jsonInfo.foreachPartition(itr => {
    //localTx有事务   autoCommit 没有事务

      DB.localTx(implicit session => {
        itr.foreach(json => {
          SQL("insert into t_provence_info values(?)").bind(json).update().apply()
        })
      })
    })
  }

}
